package initialize

//import (
//	"fmt"
//	"github.com/IMB/sarama"
//	"go.uber.org/zap"
//	"reward-server/global"
//)
//
//// newRedisPool : 创建redis连接池
//func InitKafuka() {
//
//	config := sarama.NewConfig()
//	//tailf包使用
//	config.Producer.RequiredAcks = sarama.WaitForAll          //发送完数据需要leader和follow都确认
//	config.Producer.Partitioner = sarama.NewRandomPartitioner //新选出一个partition
//	config.Producer.Return.Successes = true                   //成功交付的消息将在success channel返回
//
//	//连接kafka
//	client, err := sarama.NewSyncProducer([]string{global.ServerConfig.KafuhaUrl}, config)
//	if err != nil {
//		fmt.Println("producer closed,err:", err)
//		return
//	}
//	zap.S().Infof("获取kafuka配置信息：%v,连接信息：%v", global.ServerConfig.KafuhaUrl, client)
//	global.KaFuKaClient = client
//
//}
